package com.ruibo.config.thread;

import com.ruibo.utils.SpringContextHolder;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @CLassName ThreadPoolExecutorUtil
 * @Description 用于获取自定义线程池
 * @Author 孙峰
 * @Date 2020/1/1 14:42
 * @Version 1.0
 */
public class ThreadPoolExecutorUtil {
    public static ThreadPoolExecutor getPoll(){
        AsyncTaskProperties properties = SpringContextHolder.getBean(AsyncTaskProperties.class);
            return new ThreadPoolExecutor(properties.getCorePoolSize(),
                    properties.getMaxPoolSize(),
                    properties.getKeepAliveSeconds(),
                    TimeUnit.SECONDS,
                    new ArrayBlockingQueue<>(properties.getQueueCapacity()),
                    new TheadFactoryName());
    }
}
